5818886bae1176c6c1a947574c91ae200937661f,opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/AbstractDOMBroker.java,AbstractDOMBroker,AbstractDOMBroker,#Map#,45
Before Change
}
if (treeChange) {
extensions = ImmutableMap.of(DOMDataTreeChangeService.class, new DOMDataTreeChangeService() {
@Override
public <L extends DOMDataTreeChangeListener> ListenerRegistration<L> registerDataTreeChangeListener(
final DOMDataTreeIdentifier treeId, final L listener) {
DOMStore publisher = getTxFactories().get(treeId.getDatastoreType());
checkState(publisher != null, "Requested logical data store is not available.");
return ((DOMStoreTreeChangePublisher) publisher).registerTreeChangeListener(
treeId.getRootIdentifier(), listener);
}
});
} else {
extensions = Collections.emptyMap();
}
After Change
protected AbstractDOMBroker(final Map<LogicalDatastoreType, DOMStore> datastores) {
super(datastores);
Builder<Class<? extends DOMDataBrokerExtension>, DOMDataBrokerExtension> extBuilder = ImmutableMap.builder();
if (isSupported(datastores, DOMStoreTreeChangePublisher.class)) {
extBuilder.put(DOMDataTreeChangeService.class, new DOMDataTreeChangeService() {
@Override
public <L extends DOMDataTreeChangeListener> ListenerRegistration<L> registerDataTreeChangeListener(
final DOMDataTreeIdentifier treeId, final L listener) {
DOMStore store = getTxFactories().get(treeId.getDatastoreType());
checkState(store != null, "Requested logical data store is not available.");
return ((DOMStoreTreeChangePublisher) store).registerTreeChangeListener(
treeId.getRootIdentifier(), listener);
}
});
}
if (isSupported(datastores, org.opendaylight.mdsal.dom.api.DOMDataTreeCommitCohortRegistry.class)) {